package channelService

import "gitee.com/fierce_wolf/go-fox-edge-common/commRedisRpc"

type reportService struct {
}

func (e *reportService) popAll(channelType string, channel2event map[string]string) ([]*commRedisRpc.ChannelRespondVO, error) {
	respondVOList := make([]*commRedisRpc.ChannelRespondVO, 0)
	for channelName, event := range channel2event {
		respondVO := commRedisRpc.Type.ChannelRespondVO.New()
		respondVO.Type = channelType
		respondVO.Name = channelName
		respondVO.Recv = event

		respondVOList = append(respondVOList, respondVO)
	}

	return respondVOList, nil

}
